package cn.com.ytst.data.integration.core.channel;

import java.util.Collection;

/**
 * @ClassName Channel
 * @Deacription 数据通道
 * @Author Administrator
 * @Date 2020/1/4 0004 13:44
 * @Version 1.0
 **/
public interface PipleChannel {

    public  void doPush(String record);

    public  void doPushAll(Collection<String> records);

    public String  doPull();

    public boolean isEmpty();

    public int size();

    public void readflush();




}
